package com.mini.grpc.stream;

/**
 * 客户端响应观察者接口
 * 扩展StreamObserver，提供客户端特定的功能
 * 
 * @param <ReqT> 请求类型
 * @param <RespT> 响应类型
 * @author Mini-gRPC
 */
public interface ClientResponseObserver<ReqT, RespT> extends StreamObserver<RespT> {
    
    /**
     * 在开始接收响应之前调用
     * 可以用来配置请求流
     * 
     * @param requestStream 请求流观察者
     */
    void beforeStart(ClientStreamObserver<ReqT> requestStream);
} 